6c2c533f67044e038cb8e1567b784c541c15692f,src/test/java/com/couchbase/client/java/CouchbaseAsyncBucketTest.java,CouchbaseAsyncBucketTest,shouldNotCallIntoObserveOnRemoveWhenNotNeeded,#,109

Before Change


                core, null, "bucket", "", Collections.<Transcoder<? extends Document, ?>>emptyList()
        );

        when(core.send(any(RemoveRequest.class))).thenReturn(Observable.just((CouchbaseResponse) new RemoveResponse(
                ResponseStatus.SUCCESS, KeyValueStatus.SUCCESS.code(), 1234, "bucket", Unpooled.EMPTY_BUFFER, null, mock(CouchbaseRequest.class)
        )));

        JsonDocument doc = JsonDocument.create("foo");
        Observable<JsonDocument> result = bucket.remove(doc, PersistTo.NONE, ReplicateTo.NONE);

After Change


                core, null, "bucket", "", Collections.<Transcoder<? extends Document, ?>>emptyList()
        );

        Subject<CouchbaseResponse, CouchbaseResponse> response = AsyncSubject.create();
        response.onNext(new RemoveResponse(
            ResponseStatus.SUCCESS, KeyValueStatus.SUCCESS.code(), 1234, "bucket", Unpooled.EMPTY_BUFFER, null, mock(CouchbaseRequest.class)
        ));
        response.onCompleted();

        when(core.send(any(RemoveRequest.class))).thenReturn(response);

        JsonDocument doc = JsonDocument.create("foo");
        Observable<JsonDocument> result = bucket.remove(doc, PersistTo.NONE, ReplicateTo.NONE);